package com.xctech.yace.main;

import com.xctech.yace.service.KafkaRecived;

public class YaceRecivedTps {
    public static void main(String[] args) {

        //3.监听计算tps时间   处理数量/单位时间
        //计算公式 =  xid / cals(本笔的OCCU_TIME纳秒 - xid为0的OCCU_TIME纳秒)
        KafkaRecived recived = new KafkaRecived();
        recived.reciveMsgTps(new String[]{"YACE_TRADE"});

    }
}
